org.springframework.web.servlet.mvc.method.annotation

Class ReactiveTypeHandler.AbstractEmitterSubscriber

java.lang.Object

org.springframework.web.servlet.mvc.method.annotation.ReactiveTypeHandler.AbstractEmitterSubscriber

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

ReactiveTypeHandler.JsonEmitterSubscriber, ReactiveTypeHandler.SseEmitterSubscriber, ReactiveTypeHandler.TextEmitterSubscriber

Enclosing class:

ReactiveTypeHandler

private abstract static class ReactiveTypeHandler.AbstractEmitterSubscriber
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	done
private java.util.concurrent.atomic.AtomicReference<java.lang.Object>	elementRef
private ResponseBodyEmitter	emitter
private java.lang.Throwable	error
private java.util.concurrent.atomic.AtomicLong	executing
private Subscription	subscription
private TaskExecutor	taskExecutor
private boolean	terminated

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEmitterSubscriber(ResponseBodyEmitter emitter, TaskExecutor executor)

Method Summary

Modifier and Type	Method and Description
void	connect(ReactiveAdapter adapter, java.lang.Object returnValue)
protected ResponseBodyEmitter	getEmitter()
void	onComplete()
void	onError(java.lang.Throwable ex)
void	onNext(java.lang.Object element)
void	onSubscribe(Subscription subscription)
void	run()
private void	schedule()
protected abstract void	send(java.lang.Object element)
private void	terminate()
private void	trySchedule()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

emitter

private final ResponseBodyEmitter emitter

taskExecutor

private final TaskExecutor taskExecutor

subscription

@Nullable
private Subscription subscription

elementRef

private final java.util.concurrent.atomic.AtomicReference<java.lang.Object> elementRef

error

@Nullable
private java.lang.Throwable error

terminated

private volatile boolean terminated

executing

private final java.util.concurrent.atomic.AtomicLong executing

done

private volatile boolean done

Constructor Detail

AbstractEmitterSubscriber

protected AbstractEmitterSubscriber(ResponseBodyEmitter emitter,
                                    TaskExecutor executor)

Method Detail

connect

public void connect(ReactiveAdapter adapter,
                    java.lang.Object returnValue)

getEmitter

protected ResponseBodyEmitter getEmitter()

onSubscribe

public final void onSubscribe(Subscription subscription)

onNext

public final void onNext(java.lang.Object element)

onError

public final void onError(java.lang.Throwable ex)

onComplete

public final void onComplete()

trySchedule

private void trySchedule()

schedule

private void schedule()

run

public void run()

Specified by:

run in interface java.lang.Runnable

send

protected abstract void send(java.lang.Object element)
                      throws java.io.IOException

Throws:

java.io.IOException

terminate

private void terminate()